package elasticsearch

import (
	"context"
	"github.com/sirupsen/logrus"
)

//InsertES 这里默认index读配置文件
func InsertES(data interface{}) {
	p, err := EsClient.Index().Index(EsConfig.Index).BodyJson(data).Do(context.Background())
	if err != nil {
		logrus.Error("es: insert failed!", err)
	}
	logrus.Info("Indexed to index %s, type %s\n", EsConfig.Index, p.Type)
}
